package com.xian.cloud;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.Random;
import java.util.stream.Collectors;

/**
 * jvm中增加一个关闭的钩子，当jvm关闭的时候
 * @Author: xlr
 * @Date: Created in 下午9:39 2018/11/19
 */
public class TestShutdownHook {


    public static void main(String[] args) {



//
//        // 定义线程1
//        Thread thread1 = new Thread() {
//            @Override
//            public void run() {
//                System.out.println("thread1...");
//            }
//        };
//        // 定义线程2
//        Thread thread2 = new Thread() {
//            @Override
//            public void run() {
//                System.out.println("thread2...");
//            }
//        };
//        // 定义关闭线程
//        Thread shutdownThread = new Thread() {
//            @Override
//            public void run() {
//                System.out.println("shutdownThread...");
//            }
//        };
//        // jvm关闭的时候先执行该线程钩子
//        Runtime.getRuntime().addShutdownHook(shutdownThread);
//        try {
//            Process exec = Runtime.getRuntime().exec( "java -version" );
//            InputStream inputStream = exec.getInputStream();
//            String result = new BufferedReader(new InputStreamReader(inputStream))
//                    .lines().parallel().collect( Collectors.joining(System.lineSeparator()));
//
//            System.out.println(result);
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        int i = Runtime.getRuntime().availableProcessors();
//        System.out.println(i);
//        thread1.start();
//        thread2.start();
    }
}
